package controllers

import (
	"fmt"
	beego "github.com/beego/beego/v2/server/web"
	"shang/conmon"
)

type RabbitController struct {
	beego.Controller
}

// Publish todo: 生产者
func (r *RabbitController) Publish() {
	content := r.GetString("content")
	rabbitmq := conmon.NewRabbitMQSimple("" +
		"kuteng")
	rabbitmq.PublishSimple(content)
	r.Data["json"] = map[string]interface{}{
		"code": 200,
		"msg":  "发送成功",
	}
	r.ServeJSON()
	fmt.Println("发送成功！")
}

// SimpleOne todo: 消费者1
func (r *RabbitController) SimpleOne() {
	rabbitmq := conmon.NewRabbitMQSimple("" +
		"kuteng")
	rabbitmq.ConsumeSimple()
}

// SimpleTwo todo: 消费者2
func (r *RabbitController) SimpleTwo() {
	rabbitmq := conmon.NewRabbitMQSimple("" +
		"kuteng")
	rabbitmq.ConsumeSimple()
}
